package cn.xyfmzmy;

/**
 * 重新执行拒绝策略
 */
public class DiscardRejectHandle implements RejectHandle{
    @Override
    public void reject(Runnable rejectCommamd, MyThreadPool threadPool) {
        // 从阻塞队列中吐出来一个
        threadPool.blockingQueue.poll();
        // 再执行被拒绝的命令
        threadPool.execute(rejectCommamd);
    }
}
